package com.example.springcloud.controller;

import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.Message;

@Slf4j
@EnableBinding(Sink.class)
public class getMessageController {

    @StreamListener(Sink.INPUT)
    public void getMessage(Message<String> message) {

        log.warn("consumer8803 receive message : " + message.getPayload());
    }

}
